package com.gx.rabbit.consumer;

import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

/**
 * 用户信息消费
 *
 * @author lpj
 */
@Slf4j
@Service("fanoutConsumer")
public class FanoutConsumer extends AbstractMessageListener {
    @Override
    protected void processMessage(String msgStr) {
        //直接处理业务即可,无需关注消息接收和确认,已进行统一处理
        log.info("接收到fanout类型消息: {}", msgStr);
    }


}
